f5dcb44b2267dce05395d5c50fb2afeef04abf6d,src/main/java/uk/sky/cqlmigrate/CqlMigratorImpl.java,CqlMigratorImpl,migrate,#Session#String#Collection#,72

Before Change


        clusterHealth.check();

        CassandraLockingMechanism cassandraLockingMechanism = new CassandraLockingMechanism(session, keyspace);
        Lock lock = Lock.acquire(cassandraLockingMechanism, lockConfig);

        LOGGER.info("Loading cql files from {}", directories);
        CqlPaths paths = CqlPaths.create(directories);
        KeyspaceBootstrapper keyspaceBootstrapper = new KeyspaceBootstrapper(session, keyspace, paths);
        SchemaUpdates schemaUpdates = new SchemaUpdates(session, keyspace);
        SchemaLoader schemaLoader = new SchemaLoader(session, keyspace, schemaUpdates, paths);

        keyspaceBootstrapper.bootstrap();
        schemaUpdates.initialise();
        schemaLoader.load();
        lock.release();
    }

    /**

After Change



        CassandraLockingMechanism cassandraLockingMechanism = new CassandraLockingMechanism(session, keyspace);
        Lock lock = new Lock(cassandraLockingMechanism, lockConfig);
        lock.lock();

        LOGGER.info("Loading cql files from {}", directories);
        CqlPaths paths = CqlPaths.create(directories);